from __future__ import absolute_import, unicode_literals
import os
from celery import Celery

# 加载项目环境  manage.py 里的环境
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'meiduo_mall.settings.dev')

# 创建celery对象
app = Celery('meiduo_mall')

# 加载配置
app.config_from_object('celery_tasks.config', namespace='CELERY')

# 自动注册任务  添加自动注册任务  包里面py文件必须是 tasks命名
app.autodiscover_tasks(['celery_tasks.test','celery_tasks.sms'])

# 手动添加任务
# @app.task(bind=True)
# def debug_task(self):
#     print('debug_task')

# 启动任务 celery -A 项目工作者 worker -l INFO

# 发送任务名 任务名字.delay（参数）
'''不使用自动注册任务'''
# python manage.py shell
# >>> from celery_tasks.celery import debug_task
# >>> res = add.delay（2,3）
# >>> res.get（）

'''自动注册任务'''
# from celery_tasks.test.tasks import sum
# sum.delay(10,20)
# a = sum.delay(10,20)
# a.get()  拿数据
